package com.gitee.ixtf.rsocket

import com.gitee.ixtf.rsocket.service.GetBrokerServiceResponse
import com.gitee.ixtf.rsocket.service.ListBrokerServiceRequest
import io.rsocket.RSocket

interface IBrokerServiceAgent : IBrokerAgent {
  fun serviceRSocket(serviceRSocket: RSocket)

  suspend fun listBrokerService(
      request: ListBrokerServiceRequest
  ): Collection<GetBrokerServiceResponse>
}
